package com.pengjunlee.hive.conf;

import org.apache.spark.SparkConf;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class SparkConfig {

	@Bean(name = "sparkConf")
	@Qualifier(value = "sparkConf")
	public SparkConf sparkConf() {
		SparkConf conf = new SparkConf();
		conf.setMaster("spark://10.168.1.100:7077");
		conf.setAppName("filter App");
		conf.set("spark.streaming.stopGracefullyOnShutdown","true");
		conf.set("spark.default.parallelism", "6");
		return conf;
	}

}